Micron Document
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
| SparkN0de-git | SparkN0de |
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

Node / ReticulumProjects / LXMF.git / commits / 7b4780c


Commit 7b4780cfb7537ccc114c9a0d99da7dc6928eb113

󰉖 Browse tree at this commit

Parents : b94a712
Author : Mark Qvist <mark@unsigned.io>
Date : 2025-01-30T11:36:11+01:00

Automatically clean messages exceeding propagation transfer limit for peer from unhandled message queues

Changes

1 files changed, 1 insertions(+), 1 deletions(-)

M LXMF/LXMPeer.py +1 -1

Diff

diff --git a/LXMF/LXMPeer.py b/LXMF/LXMPeer.py
index a2b6b18..c1294bd 100644
--- a/LXMF/LXMPeer.py
+++ b/LXMF/LXMPeer.py
@@ -251,9 +251,9 @@ class LXMPeer:
next_size = cumulative_size + (lxm_size+per_message_overhead)
if self.propagation_transfer_limit != None and next_size > (self.propagation_transfer_limit*1000):
if lxm_size+per_message_overhead > (self.propagation_transfer_limit*1000):
- RNS.log(f"Message {RNS.prettyhexrep(transient_id)} exceeds transfer limit for {self}, considering handled", RNS.LOG_DEBUG)
self.remove_unhandled_message(transient_id)
self.add_handled_message(transient_id)
+ RNS.log(f"Message {RNS.prettyhexrep(transient_id)} exceeds transfer limit for {self}, considering handled", RNS.LOG_DEBUG)
else:
cumulative_size += (lxm_size+per_message_overhead)
unhandled_ids.append(transient_id)


──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────